package com.qf.rabbitmq.simple;

import com.qf.rabbitmq.util.ConnectionUtil;
import com.rabbitmq.client.*;

import java.io.IOException;
//消费者
public class Consumer {


    //    声明了一个 队列名
    private static final String QUEUENAME="bk2102";

    public static void main(String[] args) throws Exception {
//        获取连接
        Connection connection = ConnectionUtil.getConnection();
//        声明通道
        Channel channel = connection.createChannel();
//      通过通道声明队列
        channel.queueDeclare(QUEUENAME,false,false, false, null);

        /*
        * 参数1  队列的名字
        * 参数2  自动应答
        * 参数3  消费者
        * */
        channel.basicConsume(QUEUENAME,true,new DefaultConsumer(channel){
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
//                这个方法是 处理 收到消息的方法
                System.out.println(body);
                System.out.println("消费者1收到的消息是："+new String(body));
            }
        });


    }
}
